package com.wonghiu.framework.cluster.directory;

import io.netty.channel.Channel;

import java.net.InetSocketAddress;

/**
 * @Author wonghiu
 * @Date 2021/8/10 20:40
 * @Version 1.0.1
 */

public interface ConsumerDirectory {
    Channel[] get(InetSocketAddress inetSocketAddress);

    void set(InetSocketAddress inetSocketAddress, Channel channel);

    void remove(InetSocketAddress inetSocketAddress);
}
